//package com.wdd.myplatform.service;
//
//import org.apache.commons.lang3.StringUtils;
//import org.apache.pulsar.client.api.*;
//import org.slf4j.Logger;
//import org.slf4j.LoggerFactory;
//import org.springframework.beans.factory.annotation.Autowired;
//import org.springframework.stereotype.Service;
//
//import java.util.UUID;
//
///**
// *
// *
// */
//@Service
//public class PulsarService {
//    private static final Logger log = LoggerFactory.getLogger(PulsarService.class);
//
//    @Autowired
//    PulsarClient pulsarClient;
//
//    @Autowired
//    Producer producer;
//
//    @Autowired
//    private Consumer consumer;
//
//    /**
//     * sendObservation to pulsar
//     *
//     * @param data
//     * @return data
//     */
//    public String sendObservation(String data) {
//        if (StringUtils.isBlank(data)) {
//            return "";
//        }
//
//        UUID uuidKey = UUID.randomUUID();
//        MessageId msgID = null;
//        try {
//            msgID = producer.newMessage()
//                    .key(uuidKey.toString())
//                    .value(data.getBytes())
//                    .send();
//        } catch (PulsarClientException e) {
//            log.error("Pulsar client failure", e);
//        }
//        return msgID.toString();
//    }
//
//
//
//}